package com.houger.ddd.common.config.kafka;

import lombok.Data;

/**
 * 此类的描述是：生产者配置
 *
 * @date 2019-01-15 20:50
 **/
@Data
public class KafkaProducerProperties {

    /**
     * Broker 连接用户名
     */
    private String username;
    /**
     * Broker 连接密码
     */
    private String password;

    /**
     * ACK 模式
     */
    private String acks = "1";

    /**
     * 重试次数
     */
    private Integer retries = 2;

    /**
     * 延时
     */
    private Integer lingerMs = 100;

    /**
     * 批次数据大小
     */
    private Integer batchSize = 16384;

    /**
     * 缓冲区大小
     */
    private Integer bufferMemory = 33554432;
}